package com.piggy.common.core.utils.sql;

import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.piggy.common.core.exception.UtilException;
import com.piggy.common.core.utils.StringUtils;

/**
 * sql操作工具类
 *
 * @author shark
 */
public class SqlUtil
{
    /**
     * 仅支持字母、数字、下划线、空格、逗号、小数点（支持多个字段排序）
     */
    public static String SQL_PATTERN = "[a-zA-Z0-9_\\ \\,\\.]+";

    /**
     * 检查字符，防止注入绕过
     */
    public static String escapeOrderBySql(String value)
    {
        if (StringUtils.isNotEmpty(value) && !isValidOrderBySql(value))
        {
            throw new UtilException("参数不符合规范，不能进行查询");
        }
        return value;
    }

    /**
     * 验证 order by 语法是否符合规范
     */
    public static boolean isValidOrderBySql(String value)
    {
        return value.matches(SQL_PATTERN);
    }

    /**
     * 添加数据权限sql
     **/
    public static <T> LambdaQueryWrapper<T> dataPermissionFilter(Class<T> t, Long deptId) {
        LambdaQueryWrapper<T> wrapper = Wrappers.lambdaQuery(t);
        dataPermissionFilter(wrapper, deptId);
        return wrapper;
    }

    /**
     * 添加数据权限sql
     **/
    public static <T> void dataPermissionFilter(LambdaQueryWrapper<T> wrapper, Long deptId) {
        wrapper.apply(getDataPermissionSql(deptId));
    }

    /**
     * 添加数据权限sql
     **/
    public static <T> void dataPermissionFilter(QueryWrapper<T> wrapper, Long deptId) {
        wrapper.apply(getDataPermissionSql(deptId));
    }

    /**
     * 获取数据权限sql
     **/
    public static String getDataPermissionSql(Long deptId){
        return StrUtil.format("dept_id in (SELECT dept_id FROM logi_sys_dept WHERE dept_id = {} or find_in_set( {} , ancestors ))", deptId, deptId);
    }
}
